/**
 * 2018年11月27日下午9:23:22
 * @author 谢进财
 */
package com.baihang.project.ds.dao;

import java.sql.PreparedStatement;
import java.sql.SQLException;

import org.springframework.jdbc.core.BatchPreparedStatementSetter;
import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;

import com.baihang.framework.dao.BaseDao;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

@Repository
public class CustomerOneDao extends BaseDao {
	@Transactional
	public boolean batchInsertCustomerOneList(JSONArray jsonArray,int source) {
		String sql = "insert into t_user (D_HouseName,D_Name,D_Sex,D_Tel,D_Card,D_FromType,D_OperationName,D_OperationDate,D_lastLoginTime,D_Source) values (?,?,?,?,?,?,?,?,?,?)";
		super.getJdbcTemplate().batchUpdate(sql, new BatchPreparedStatementSetter() {
			public int getBatchSize() {
				return jsonArray.size();
				// 这个方法设定更新记录数，通常List里面存放的都是我们要更新的，所以返回list.size();
			}

			public void setValues(PreparedStatement ps, int i) throws SQLException {
				JSONObject jsonObject = jsonArray.getJSONObject(i);
				ps.setString(1, jsonObject.getString("D_HouseName"));
				ps.setString(2, jsonObject.getString("D_Name"));
				ps.setString(3, jsonObject.getString("D_Sex"));
				ps.setString(4, jsonObject.getString("D_Tel"));
				ps.setString(5, jsonObject.getString("D_Card"));
				ps.setString(6, jsonObject.getString("D_FromType"));
				ps.setString(7, jsonObject.getString("D_OperationName"));
				ps.setString(8, jsonObject.getString("D_OperationDate"));
				ps.setString(9, jsonObject.getString("D_lastLoginTime"));
				ps.setInt(10, source);
				
			}
		});

		return true;
	}
}
